package com.central.rearService.mq

import org.springframework.cloud.stream.annotation.EnableBinding
import org.springframework.cloud.stream.annotation.Input
import org.springframework.messaging.SubscribableChannel

/**
 * @author  fly
 * @date  2021/6/1 14:33
 * @version 1.0
 */

const val POST_INPUT = "post_input"

@EnableBinding(RearSink::class)
open class RearMqConfig

interface RearSink{

    @Input(POST_INPUT)
    fun postTopicInput(): SubscribableChannel
}